package org.leafDomain.file;

import org.apache.hadoop.hbase.client.Put;
import org.leafDomain.common.Com;

import java.io.IOException;
import java.util.List;

/**
 * 以文件作为数据源
 */
public interface FileSource extends Com {
    /**
     * 以参数 container 的容量作为批处理的数量
     * @param container 可以重复使用的容器
     * @return  表示是否存在下一个有效批次
     */
    boolean read(List<Put> container) throws IOException;

    /**
     *  获取单批次处理数据的量
     * @return 量
     */
    int batchSize();

}
